package session

import (
	"gitee.com/DengAnbang/streamWeb/api/dbops"
	"encoding/json"
)

func loadSessionFormDB() error {
	strings, err := dbops.ListSession()
	if err != nil {
		return err
	}
	for _, s := range strings {
		var sion sessionBean
		err := json.Unmarshal([]byte(s), &sion)
		if err != nil {
			continue
		}
		addSession(&sion)
	}
	return nil
}

func deleteSessionToDB(sessionID string) error {
	return dbops.DeleteSession(sessionID)
}

func addSessionToDB(s *sessionBean) error {
	bytes, err := json.Marshal(s)
	if err != nil {
		return err
	}
	return dbops.AddSession(s.SessionID,s.UserID, string(bytes))
}
